package cn.com.tt.flink.sql.engine.pojo.sql.factory;

import cn.com.tt.flink.sql.engine.pojo.sql.AbstractBmFlinkSql;
import cn.com.tt.flink.sql.engine.pojo.sql.BmUseCatalogSql;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class UseCatalogFactory implements BmSqlFactory {
    @Override
    public AbstractBmFlinkSql createSql(String sql, StreamTableEnvironment tableEnv) {
        return new BmUseCatalogSql(sql, tableEnv);
    }
}
